from airflow.sdk import Variable,dag, task
import pendulum
import sys
import os

# Dynamically add the dags folder to Python path
sys.path.append(os.path.dirname(os.path.abspath(__file__)))


from utils.my_util import hello_util


@dag(
    schedule=None,
    start_date=pendulum.datetime(2021, 1, 1, tz="UTC"),
    catchup=False, # 是否开启回填
    tags=["example"],
)
def demo():
    """
    hello utils
    """

    @task
    def get_function():
        """
        get function from third py 
        """
        hello_util()

    get_function()
demo()